7056ef0b16f15ce28816e30493e28148d9122b30,opennms-icmp/opennms-icmp-api/src/main/java/org/opennms/netmgt/ping/Pinger.java,Pinger,processTimeouts,#,83
Before Change
}
protected void processTimeouts() {
synchronized(waiting) {
for (PingRequest request : waiting.values()) {
request.processTimeout();
}
}
}
After Change
}
protected void processTimeouts() {
synchronized(waiting) {
for (Iterator<Entry<Long, PingRequest>> it = waiting.entrySet().iterator(); it.hasNext(); ) {
PingRequest request = it.next().getValue();
ThreadCategory.getInstance(this.getClass()).debug("checking request " + request);
if (request.isExpired()) {
it.remove();
PingRequest retry = request.processTimeout();
if (retry != null) {
waiting.put(retry.getTid(), retry);
retry.sendRequest(icmpSocket);
}
}
}